/*
 * core_mqtt.h
 *
 */

#ifndef MQTT_APP_H_
#define MQTT_APP_H_

#include "user.h"


#define MQTT_TIME_OUT_DEF     200

extern int rid;
extern unsigned char mqtt_connect_sta;    //
extern unsigned char mqtt_data_sta;
extern unsigned char update_refresh;

int mqtt_login(void);
int mqtt_heartbeat(void);
int mqtt_data_update(void);

int mqtt_Response(const char *resp,unsigned int rid);
void mqtt_rev_callback(unsigned char *pay_load);
int mqtt_data_update_oil(void);



#endif /* SRC_MQTT_CORE_MQTT_H_ */






